package com.zhb.zhbojbackendjudgeservice.rabbitmq;

import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Slf4j
@Component
public class TtlQueueConsumer { // 监听死信队列的消息
    @SneakyThrows
    @RabbitListener(queues = {"dead_queue"})
    public void receiveFromDeadQueue(String message) {
        log.info("从死信队列接收到消息: {}", message);
        // 在这里处理死信队列中的消息，可能是进行日志记录、报警等处理
        // 例如将消息保存到数据库，或者通知相关人员

        // 例如这里可以做一些特殊处理，比如报警、重试等
        log.info("已经接收到死信消息");
    }
}
